package com.gs.study.rabbitmq.receiver;

import java.awt.print.Book;
import java.io.IOException;
import java.time.LocalDateTime;
import java.util.concurrent.CountDownLatch;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.rabbitmq.client.Channel;

/**
 * @author gaoshang 
 * @date 创建时间：2018年5月7日 下午5:37:08 
 */
public class Receiver {
    private CountDownLatch latch = new CountDownLatch(1);


/*    public CountDownLatch getLatch() {
        return latch;
    }
    
    
    public void receiveMessage(String msg) {
        System.out.println("topic.message : " + msg);
        latch.countDown();
    }
    
    public void receiveMessages(String msg) {
        System.out.println("topic.messages : " + msg);
        latch.countDown();
    }
    public void hello(String msg) {
        System.out.println("hello www: " + msg);
        latch.countDown();
    }
    
    
    
    public void fanoutA(User user) {
        System.out.println("fanoutA : " + user.toString());
        latch.countDown();
    }
    
    public void fanoutB(User user) {
        System.out.println("fanoutB : " + user.toString());
        latch.countDown();
    }

    public void fanoutC(User user) {
        System.out.println("fanoutC : " + user.toString());
        latch.countDown();
    }*/
    
}
